package com.min.kafka;

import org.springframework.kafka.support.SendResult;

public interface SendCallBack {

    /**
     * 消息发送成功回调
     * @return: void
     * @author: fengt
     * @date: 2021/4/2 16:48
     *
     * @param objectObjectSendResult*/
    void successToDo(SendResult<Object, Object> objectObjectSendResult);

    /**
     * 消息发送失败回调
     * @return: void
     * @author: fengt
     * @date: 2021/4/2 16:48
     *
     * @param throwable*/
    void failureToDo(Throwable throwable);

}
